217c49a8c550422f0685099aa797aaa77e513605,src/main/java/com/continuuity/data/operation/ttqueue/TTQueueNewOnVCTable.java,TTQueueNewOnVCTable,invalidate,#QueueEntryPointer#number#,145
Before Change
cleanWriteVersion, new EntryMeta(EntryMeta.EntryState.INVALID).getBytes());
// Delete data since it's invalidated
this.table.delete(rowName, ENTRY_DATA, cleanWriteVersion);
if (TRACE) log("Invalidated " + entryPointer);
}
@Override
After Change
cleanWriteVersion, new EntryMeta(EntryMeta.EntryState.INVALID).getBytes());
// Delete data since it's invalidated
this.table.delete(rowName, ENTRY_DATA, cleanWriteVersion);
if (LOG.isTraceEnabled()) {
LOG.trace("Invalidated " + entryPointer);
}
}